package cn.ddm.hrm.handler;

import cn.ddm.hrm.config.RabbitMQConfig;
import com.rabbitmq.client.AMQP;
import com.rabbitmq.client.Channel;
import org.springframework.amqp.core.Message;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

import java.util.List;

@Component
public class MQHandler {

    /**
     * 发送邮件
     * @param ids
     * @param msg
     * @param channel
     */
    @RabbitListener(queues = RabbitMQConfig.QUEUE_NAME_EMAIL)
    public void emailHandler(List<Long> ids, Message msg , Channel channel){
        // 准备要发送的消息
        String message = "亲爱的用户，我们课程【"+ids+"】课程已经上线，请查收。";
        System.out.println("邮件发送：" + message);
    }

    /**
     * 发送短信
     * @param ids
     * @param msg
     * @param channel
     */
    @RabbitListener(queues = RabbitMQConfig.QUEUE_NAME_SMS)
    public void smsHandler(List<Long> ids, Message msg , Channel channel){
        // 准备要发送的消息
        String message = "亲爱的用户，我们课程【"+ids+"】课程已经上线，请查收。";
        System.out.println("短信发送：" + message);
    }

    /**
     * 发送站内信
     * @param ids
     * @param msg
     * @param channel
     */
    @RabbitListener(queues = RabbitMQConfig.QUEUE_NAME_SYSTEM_MESSAGE)
    public void systemMessageHandler(List<Long> ids, Message msg , Channel channel){
        // 准备要发送的消息
        String message = "亲爱的用户，我们课程【"+ids+"】课程已经上线，请查收。";
        System.out.println("站内信发送：" + message);
    }
}
